package datahub

type CreateTopicParameter struct {
	ShardCount   int
	LifeCycle    int
	Comment      string
	RecordType   RecordType
	RecordSchema *RecordSchema
	ExpandMode   ExpandMode
}

type UpdateTopicParameter struct {
	LifeCycle int
	Comment   string
}

type CreateConnectorParameter struct {
	SinkStartTime int64
	ConnectorType ConnectorType
	ColumnFields  []string
	ColumnNameMap map[string]string
	Config        interface{}
}

type UpdateConnectorParameter struct {
	ColumnFields  []string
	ColumnNameMap map[string]string
	Config        interface{}
}
